e4b5535ea186352ece0304f79e5a65535ff8c205,cdap-app-templates/cdap-etl/cdap-etl-batch/src/main/java/co/cask/cdap/templates/etl/batch/ETLMapReduce.java,ETLMapReduce,prepareSource,#MapReduceContext#ETLStage#,88
Before Change
private void prepareSource(MapReduceContext context, ETLStage sourceStage) throws Exception {
String sourcePluginId = context.getRuntimeArguments().get(Constants.Source.PLUGINID);
BatchSource source = context.newPluginInstance(sourcePluginId);
BatchSourceContext sourceContext = new MapReduceSourceContext(context, mrMetrics, sourcePluginId);
LOG.info("Source Stage : {}", sourceStage);
LOG.info("Source Class : {}", source.getClass().getName());
After Change
}
private void prepareSource(MapReduceContext context, ETLStage sourceStage) throws Exception {
sourcePluginId = context.getRuntimeArguments().get(Constants.Source.PLUGINID);
batchSource = context.newPluginInstance(sourcePluginId);
BatchSourceContext sourceContext = new MapReduceSourceContext(context, mrMetrics, sourcePluginId);
LOG.info("Source Stage : {}", sourceStage);
LOG.info("Source Class : {}", batchSource.getClass().getName());